#if !defined(_APP_MQTT_H)
#define _APP_MQTT_H

#define ADDRESS "tcp://192.168.52.1:1883"
#define CLIENTID "4dc91415-5845-4110-9a32-0fc059fe6dc9"
#define TOPIC_PULL "pull"  // 接收消息的主题
#define TOPIC_PUSH "push" // 发送消息的主题
#define QOS 1
#define TIMEOUT 10000L

/**
 * 初始化MQTT客户端
 */
int app_mqtt_init();

/**
 * 发送消息
 */
int app_mqtt_send(char *data, int len);

/**
 * 注册接收消息的回调函数
 */
void app_mqtt_registRecvCallback(int (*callback)(char *, int));

/**
 * 关闭MQTT客户端
 */
void app_mqtt_close();

#endif // _APP_MQTT_H
